package com.xbongbong.workflow.rabbitmq.binders;

import com.xbongbong.workflow.rabbitmq.constant.ScheduleTaskMqConsumerConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

@Service("scheduleTaskMqConsumerBinder")
public interface ScheduleTaskMqConsumerBinder {

    @Input(ScheduleTaskMqConsumerConstant.SCHEDULE_TASK_INPUT)
    SubscribableChannel scheduleTaskInput();

    @Input(ScheduleTaskMqConsumerConstant.SCHEDULE_TASK_IMMEDIATELY_INPUT)
    SubscribableChannel scheduleTaskImmediatelyInput();

}
